package com.ming.rabbitmq.two;

import com.ming.rabbitmq.util.RabbitMqUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.util.Scanner;

public class Producer1 {
    //    队列名称
    public static String name = "hello";

    //    发消息
    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMqUtils.getChannel();
//    获取队列
//                     队列名 是否持久化 是否和其他消费者共享 是否自动删除 其他参数
        channel.queueDeclare(name, false, false, false, null);
        Scanner scanner = new Scanner(System.in);
        while (scanner.hasNext()) {
            String message = scanner.next();
//    发布信息
//        交换机 （路由key值）队列名 其他参数 消息体
            channel.basicPublish("", name, null, message.getBytes());
            System.out.println("消息发送完毕");
        }
    }


}
